package com.infoauto.opc.gateway.messages.handler;


import com.infoauto.opc.gateway.messages.util.GenericsUtils;
import org.eclipse.milo.opcua.stack.core.types.builtin.Variant;


public abstract class RabbitMQListener<T> {

    //获取消息
    public abstract boolean onMessage(String exchangeName, String routingKey, String queueName, T message, Variant variant);

    public Class getGenericType() {
        return GenericsUtils.getSuperClassGenericType(getClass());
    }
}
